package com.edclol.apitest.sink;
/**
 * Created by admin on 2021/1/28 11:52
 */

/**
 * JessePinkMan
 */
public class readeFromKafkaa {

    public static void main(String[] args) throws Exception {
        KafkaProducerUtil.readeFromKafka("json1");
    }
}
